//package com.ytjj.qmyx.mall.service.impl;
//
//import com.ytjj.qmyx.mall.kafka.*;
//import com.ytjj.qmyx.mall.service.KafkaSendService;
//import lombok.extern.log4j.Log4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.messaging.support.MessageBuilder;
//import org.springframework.stereotype.Service;
//
//@Log4j
//@Service
//@EnableBinding({IPvKafkaOut.class, IOrderRecordKafkaOut.class, IClickStatisticsKafkaOut.class, IProductStatisticsKafkaOut.class, IAppActivationKafkaOut.class})
//public class KafkaSendServiceImpl implements KafkaSendService {
////    @Autowired
////    private IPvKafkaOut pvKafkaOut;
//    @Autowired
//    private IOrderRecordKafkaOut orderRecordKafkaOut;
//    @Autowired
//    private IClickStatisticsKafkaOut clickStatisticsKafkaOut;
//    @Autowired
//    private IProductStatisticsKafkaOut productStatisticsKafkaOut;
//    @Autowired
//    private IAppActivationKafkaOut appActivationKafkaOut;
//
//    @Override
//    public boolean sendPvMsg(String msg) {
//        return false;//pvKafkaOut.output().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendPvNewMsg(String msg) {
//        return false;//pvKafkaOut.pvNewOutput().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendOrderRecordMsg(String msg) {
//        return orderRecordKafkaOut.output().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendOrderRecordHistoryDeleteMsg(String msg) {
//        return orderRecordKafkaOut.orderRecordHistoryOutput().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendOrderRecordNewMsg(String msg) {
//        return orderRecordKafkaOut.newOutput().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendClickMsg(String msg) {
//        return clickStatisticsKafkaOut.output().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendProductMsg(String msg) {
//        return productStatisticsKafkaOut.output().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendPvHistoryMsg(String msg) {
//        return false;//pvKafkaOut.historyOutput().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendOrderRecordHistoryMsg(String msg) {
//        return orderRecordKafkaOut.historyOutput().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendProductHistoryMsg(String msg) {
//        return productStatisticsKafkaOut.historyOutput().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendAppActivaionMsg(String msg) {
//        return appActivationKafkaOut.appActivation().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendAppUserActiveMsg(String msg) {
//        return appActivationKafkaOut.appUserActive().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendAppUserBehavior(String msg) {
//        return appActivationKafkaOut.appUserBehavior().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendAppUserRegister(String msg) {
//        return appActivationKafkaOut.appUserRegister().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendDynamicCheckPass(String msg) {
//        return appActivationKafkaOut.sendDynamicCheckPass().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendDynammicComment(String msg) {
//        return appActivationKafkaOut.sendDynammicComment().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendDynamicLike(String msg) {
//        return appActivationKafkaOut.sendDynamicLike().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendDynamicExposure(String msg) {
//        return appActivationKafkaOut.sendDynamicExposure().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendUsersInfo(String msg) {
//        return appActivationKafkaOut.sendUsersInfo().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendUserFansInfo(String msg) {
//        return appActivationKafkaOut.sendUserFansInfo().send(MessageBuilder.withPayload(msg).build());
//    }
//
//    @Override
//    public boolean sendDynamicHistory(String msg) {
//        return appActivationKafkaOut.sendDynamicCheckPass().send(MessageBuilder.withPayload(msg).build());
//    }
//}
